package com.example.hbase;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;

import java.io.IOException;

/**
 * Created with IntelliJ IDEA.
 * ClassName: HBaseThread
 * Package: com.example.hbase
 * Description:
 * User: fzykd
 *
 * @Author: LQH
 * Date: 2023-08-03
 * Time: 21:21
 */

//多线程创建连接
public class HBaseThread {

    //声明静态属性
    public static Connection connection;

    //是一个重量级的连接 建议在使用的时候创建一个连接即可
    //那么就使用单例的创建
    static {
        //1.创建连接配置对象
        //Configuration conf = new Configuration();
        //2.添加配置参数 这些配置参数 按理说是配置在 配置文件当中的
        //在配置文件中 写了就不用在写了
        //conf.set("hbase.zookeeper.quorum","hadoop102,hadoop103,hadoop104");
        //3.创建连接
        try {
            //1.直接创建连接
            connection = ConnectionFactory.createConnection();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) throws IOException {
        //直接使用连接
        System.out.println(connection);
        //关闭连接
        connection.close();

    }
}
